package com.mjf.spark.day04

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

/**
 * 转换算子-foldByKey
 *    对pairRDD中的value部分进行映射
 */
object Spark08_Transformation_mapValues {
  def main(args: Array[String]): Unit = {

    // 创建SparkConf配置文件
    val conf = new SparkConf().setMaster("local[*]").setAppName("Spark08_Transformation_mapValues")
    // 创建SparkContext对象
    val sc = new SparkContext(conf)

    val rdd: RDD[(Int, String)] = sc.makeRDD(List((1, "a"), (1, "d"), (2, "b"), (3, "c")))

    // 在pairRDD的value部分前面加|||
    val resRDD: RDD[(Int, String)] = rdd.mapValues("|||".concat(_))

    resRDD.collect().foreach(println)

    // 关闭连接
    sc. stop()

  }
}

